package com.example.rocketmqspringbootdemo.config;

import org.apache.rocketmq.spring.annotation.ExtRocketMQTemplateConfiguration;
import org.apache.rocketmq.spring.core.RocketMQTemplate;

/*可以自定义RocketMQTemplate的配置: 比如多源的情况下可以配置,该注解定义了value、nameServer、group、sendMessageTimeout、
compressMessageBodyThreshold、retryTimesWhenSendFailed、retryTimesWhenSendAsyncFailed、retryNextServer、maxMessageSize、
accessKey、secretKey、enableMsgTrace、customizedTraceTopic等属性*/
@ExtRocketMQTemplateConfiguration(nameServer = "${rocketmq.ext.NameServer}")
public class ExtRocketMQTemplate extends RocketMQTemplate {

}
